51a451300a1af7cf7bc01e53befb03bbcbc89e82,spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java,KafkaBinderTests,testAutoCreateTopicsEnabledSucceeds,#,596

Before Change



	@Test
	public void testAutoCreateTopicsEnabledSucceeds() throws Exception {
		KafkaMessageChannelBinder binder = new KafkaMessageChannelBinder(
				new ZookeeperConnect(kafkaTestSupport.getZkConnectString()), kafkaTestSupport.getBrokerAddress(),
				kafkaTestSupport.getZkConnectString());
		GenericApplicationContext context = new GenericApplicationContext();
		binder.setAutoCreateTopics(true);
		context.refresh();
		binder.setApplicationContext(context);
		binder.afterPropertiesSet();

After Change



	@Test
	public void testAutoCreateTopicsEnabledSucceeds() throws Exception {
		KafkaBinderConfigurationProperties configurationProperties = createConfigurationProperties();
		configurationProperties.setAutoCreateTopics(true);
		KafkaMessageChannelBinder binder = new KafkaMessageChannelBinder(configurationProperties);
		GenericApplicationContext context = new GenericApplicationContext();
		context.refresh();
		binder.setApplicationContext(context);